package org.wang.portal.core;

import org.wang.portal.tool.KafkaManager;

public class KafkaOperationStrategy implements OperationStrategy {
    @Override
    public void execute(String[] args) {
        if (args.length < 2) {
            System.out.println("Usage: Main kafka <start/stop>");
            System.exit(1);
        }
        KafkaManager kafkaManager = new KafkaManager();
        kafkaManager.executeAction(args[1]);
    }
}